package xyz.yuanjilu.service;

import java.io.IOException;


import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Consumer;
import com.rabbitmq.client.Envelope;

/**
 * 消息订阅者
 * @author qiyang
 *
 */
public interface MQSubscribe extends Consumer{
	 public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException;
}
